重走Java基础之Streams 一

因为经常逛stackoverflow,最近也在看reactive和storm以及前一阵子也用流式ORM框架speedment与Springboot整合改造了migo2.0中的单点登录,深深的感受到java8已经融入我们很深了，尤其是Spring5对其进行大力支持，觉得有必要再对自己的知识整理一下，顺带就把stackoverflow一些东西自己拿过来整理翻译一下，里面也会加入一些自己的理解版本只关注于Java SE 8

Introduction

流表示一系列元素并支持不同类型的操作来对这些元素执行计算。在Java 8中，Collection接口有两种方法来生成Stream

1）stream()和
2） parallelStream()
流操作包括中间或终端。中间操作返回一个流，所以我们可以链接多个中间操作而不使用分号。终端操作是void的或返回非流结果。

Examples

Using Streams

A Stream是可以执行顺序和并行聚合操作的一系列元素。任何给定的“Stream”都可能有无限量的数据流过它。你所得到的结果是从“Stream”接收的数据在到达时被单独处理，而不是完全对数据执行批处理。当与lambda表达式结合时，它们提供了使用函数方法对数据序列执行操作的简明方法。

Example: (see it work on Ideone)

Stream<String> fruitStream = Stream.of("apple", "banana", "pear", "kiwi", "orange");

fruitStream.filter(s -> s.contains("a"))
           .map(String::toUpperCase)
           .sorted()
           .forEach(System.out::println);

Output:

APPLE
BANANA
ORANGE
PEAR

上述代码执行的操作可以总结如下：

使用静态工厂方法Stream.of(values)创建一个包含fruit String的顺序排序Stream的Stream 元素
filter()操作仅保留与给定谓词（由谓词返回true测试时的元素）匹配的元素。在这种情况下，它保留含有“a”的元素。谓词作为lambda表达式给出。
map() 操作转换每个元素使用给定的函数，称为映射器。在这种情况下，每个fruit String使用method-reference映射到将string字符串转换为大写版本String::toUppercase。

Note 如果映射函数返回与其输入参数不同的类型，那么map()操作将返回具有不同泛型类型的流。例如在一个Stream调用.map(String :: isEmpty)返回一个Stream<Boolean>
sorted()操作对Stream的元素进行排序根据它们的自然排序（根据在’String’的情况下对所在字典的顺序，其实都知道）。

5.最后， forEach(action) 操作执行一个动作，作用于“Stream”的每个元素，将其传递给一个 Consumer。在该示例中，每个元素只是被打印到控制台。该操作是终端操作，因此不可能再次进行操作。
6.

Note 在Stream中定义的操作之所以被执行，是因为最后有终端操作。假如没有终端操作，’Stream’将不被处理，因为’Stream’输出不被任何终端操作使用(省的浪费计算资源，所以很多书上称之为被动式foreach)。

[

操作（如上所示）链接在一起以形成可以被视为对数据的查询

Reusing Streams

一个Stream不能重复使用。一旦调用任何中间或终端操作，“Stream”对象将变得不可用。 Stream代替地使用中间Stream对象以便将中间操作链接在一起通过一系列Stream操作来生成一个Stream对象作为中间对象，最后再调用这个生成的Stream对象来完成最终的操作，最后一步的操作只能进行一次，之后，此流已经没了(生命周期已结束)。

Example:

Stream<String> stream =
    Stream.of("d2", "a2", "b1", "b3", "c")
        .filter(s -> s.startsWith("a"));

stream.anyMatch(s -> true);  // The Stream has been used and is now consumed.
stream.noneMatch(s -> true); // IllegalStateException; stream was already used

Closing Streams

Stream接口扩展了 AutoCloseable。Streams可以通过调用 close方法或使用try-with -resource语句来关闭。

请注意，Stream通常不必关闭。仅需要关闭在IO通道上运行的流。大多数Stream 型不对资源操作，因此不需要关闭。

Stream 应该关闭的示例用例是，当您从文件创建一个Stream 行时：

1
2
3

try(final Stream<String> lines = Files.lines(Paths.get("somePath"))){
    lines.forEach(System.out::println);
}

Stream接口也声明了Stream.onClose() 方法，它允许你注册 Runnable处理程序，当流关闭。一个示例用例是产生流的代码需要知道它何时被消耗以执行一些清理。

public Stream<String>streamAndDelete(Path path) throws IOException {
    return Files.lines(path)
        .onClose(()->someClass.deletePath(path));
}

运行处理程序只有在调用close() 方法时才会执行，例如通过try-with-resources：

Path myPath = Paths.get("somePath");

try(final Stream<String> lines = streamAndDelete(myPath)){
    lines.forEach(System.out::println);
}
Files.exists(myPath); // returns false

If close() isn’t called, explicitly or implicitly, then the handler will not be called either:
如果没有明确或隐式地调用close()，那么处理程序不会被调用：

1
2
3

streamAndDelete(myPath)
    .forEach(System.out::println);
Files.exists(myPath); // returns true

Processing Order

Stream对象的处理可以是顺序或 parallel(并行)。

在 sequential 模式中，按照“Stream”的源的顺序处理元素。如果Stream是有序的（例如 SortedMap实现或List，处理过程保证匹配源的排序。然而，在其他情况下，应注意不要依赖于顺序（参见：是Java的HashMap`` keySet()迭代顺序一致？）。

Example:

List<Integer> integerList = Arrays.asList(0, 1, 2, 3, 42); 

// sequential 
long howManyOddNumbers = integerList.stream()
                                    .filter(e -> (e % 2) == 1).count(); 

System.out.println(howManyOddNumbers); // Output: 2

Live on Ideone

并行模式允许在多个核上使用多个线程，但不能保证处理元素的顺序。

如果在顺序的 Stream 上虽然调用了多个方法，则不一定必须要调用每个方法。例如，如果一个 Stream 被过滤，并且元素的数量减少到一，则不会发生对诸如sort的方法的后续调用。这可以提高顺序的Stream的性能 - 这是一个并行的Stream不可能实现的优化。

Example:

// parallel
long howManyOddNumbersParallel = integerList.parallelStream()
                                            .filter(e -> (e % 2) == 1).count();

System.out.println(howManyOddNumbersParallel); // Output: 2

Live on Ideone